package main

import (
	"lnzw/engine/log"
	"lnzw/engine/nats"

	"go.uber.org/zap"
)

func main() {
	log.Setup()
	nats.Setup()
	// nats.SyncQueueReply("test", "test", func(msg []byte, ch chan<- []byte) {
	// 	log.Info("test", zap.String("msg", string(msg)))
	// 	ch <- []byte("recv")
	// })

	nats.SyncReply("test", func(msg []byte, ch chan<- []byte) {
		log.Info("test", zap.String("msg", string(msg)))
		ch <- []byte("recv")
	})
}
